from airflow.operators.hive_operator import HiveOperator

from jms.dwd.dwd_cn_address_warehouse_day_dt import jms_dwd__dwd_cn_address_warehouse_day_dt
from jms.dwd.dwd_cn_address_warehouse_es_dt import jms_dwd__dwd_cn_address_warehouse_es_dt

jms_dm__cn_address_warehouse_day_rule_dt= HiveOperator(
    task_id='jms_dm__cn_address_warehouse_day_rule_dt',
    mapred_queue='pro',
    hql='jms/dm/cn_address_warehouse_day_rule/execute.hql',
    pool_slots=4,
    email=['yushuo@jtexpress.com','yl_bigdata@yl-scm.com'],
)


jms_dm__cn_address_warehouse_day_rule_dt << [jms_dwd__dwd_cn_address_warehouse_day_dt, jms_dwd__dwd_cn_address_warehouse_es_dt]